Node / meshtastic / Meshtastic-Android / files / core / data / src / jvmTest / kotlin / org / meshtastic / core / data / repository / DeviceHardwareRepositoryImplTest.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.core.data.repository

Tff7b72import T7ee787kotlinx.coroutines.CompletableDeferred

Tff7b72import T7ee787kotlinx.coroutines.Dispatchers

Tff7b72import T7ee787kotlinx.coroutines.async

Tff7b72import T7ee787kotlinx.coroutines.awaitAll

Tff7b72import T7ee787kotlinx.coroutines.coroutineScope

Tff7b72import T7ee787kotlinx.coroutines.flow.Flow

Tff7b72import T7ee787kotlinx.coroutines.flow.flowOf

Tff7b72import T7ee787kotlinx.coroutines.runBlocking

Tff7b72import T7ee787kotlinx.serialization.json.Json

Tff7b72import T7ee787okio.Buffer

Tff7b72import T7ee787okio.Source

Tff7b72import T7ee787org.meshtastic.core.data.datasource.BundledAssetReader

Tff7b72import T7ee787org.meshtastic.core.data.datasource.DeviceHardwareLocalDataSource

Tff7b72import T7ee787org.meshtastic.core.di.CoroutineDispatchers

Tff7b72import T7ee787org.meshtastic.core.model.DeviceLink

Tff7b72import T7ee787org.meshtastic.core.model.EventFirmwareResponse

Tff7b72import T7ee787org.meshtastic.core.model.FirmwareReleaseManifest

Tff7b72import T7ee787org.meshtastic.core.model.NetworkDeviceHardware

Tff7b72import T7ee787org.meshtastic.core.model.NetworkDeviceLinksResponse

Tff7b72import T7ee787org.meshtastic.core.model.NetworkFirmwareNightly

Tff7b72import T7ee787org.meshtastic.core.model.NetworkFirmwareReleases

Tff7b72import T7ee787org.meshtastic.core.network.DeviceHardwareRemoteDataSource

Tff7b72import T7ee787org.meshtastic.core.network.service.ApiService

Tff7b72import T7ee787org.meshtastic.core.repository.DeviceLinkRepository

Tff7b72import T7ee787org.meshtastic.core.testing.FakeDatabaseProvider

Tff7b72import T7ee787kotlin.test.AfterTest

Tff7b72import T7ee787kotlin.test.BeforeTest

Tff7b72import T7ee787kotlin.test.Test

Tff7b72import T7ee787kotlin.test.assertEquals

Tff7b72import T7ee787kotlin.test.assertFalse

Tff7b72import T7ee787kotlin.test.assertNull

Tff7b72import T7ee787kotlin.test.assertTrue

Tff7b72class T56d364DeviceHardwareRepositoryImplTest Tb4b4b4{

Tff7b72private Tff7b72class T56d364FakeApiServiceTb4b4b4(Tff7b72var Te6edf3responseTb4b4b4: Te6edf3ListTff7b72<Te6edf3NetworkDeviceHardwareTff7b72>Tb4b4b4) Tb4b4b4: Te6edf3ApiService Tb4b4b4{

Tff7b72var Te6edf3hardwareCalls Tff7b72= T79c0ff0

Tff7b72var Te6edf3responseGateTb4b4b4: Te6edf3CompletableDeferredTff7b72<Tffa657UnitTff7b72>Tff7b72? Tff7b72= Tff7b72null

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetDeviceHardwareTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3ListTff7b72<Te6edf3NetworkDeviceHardwareTff7b72> Tb4b4b4{

Te6edf3hardwareCalls Tff7b72+Tff7b72= T79c0ff1

Te6edf3responseGateTff7b72?.Te6edf3awaitTb4b4b4(Tb4b4b4)

Tff7b72return Te6edf3response

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetDeviceLinksTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3NetworkDeviceLinksResponse Tff7b72= Te6edf3errorTb4b4b4(Ta5d6ff"Ta5d6ffunusedTa5d6ff"Tb4b4b4)

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetFirmwareReleasesTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3NetworkFirmwareReleases Tff7b72= Te6edf3errorTb4b4b4(Ta5d6ff"Ta5d6ffunusedTa5d6ff"Tb4b4b4)

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetFirmwareReleaseManifestTb4b4b4(Te6edf3manifestUrlTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Te6edf3FirmwareReleaseManifest Tff7b72= Te6edf3errorTb4b4b4(Ta5d6ff"Ta5d6ffunusedTa5d6ff"Tb4b4b4)

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetNightlyFirmwareTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3NetworkFirmwareNightly? Tff7b72= Te6edf3errorTb4b4b4(Ta5d6ff"Ta5d6ffunusedTa5d6ff"Tb4b4b4)

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetEventFirmwareTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3EventFirmwareResponse Tff7b72= Te6edf3errorTb4b4b4(Ta5d6ff"Ta5d6ffunusedTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72class T56d364FakeBundledAssetReaderTb4b4b4(Tff7b72var Te6edf3hardwareTb4b4b4: Te6edf3ListTff7b72<Te6edf3NetworkDeviceHardwareTff7b72>Tb4b4b4, Tff7b72private Tff7b72val Te6edf3jsonTb4b4b4: Te6edf3JsonTb4b4b4) Tb4b4b4:

Te6edf3BundledAssetReader Tb4b4b4{

Tff7b72override Tff7b72fun Td2a8ffopenTb4b4b4(Te6edf3nameTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Te6edf3Source? Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3name Tff7b72!Tff7b72= Ta5d6ff"Ta5d6ffdevice_hardware.jsonTa5d6ff"Tb4b4b4) Tff7b72return Tff7b72null

Tff7b72return Te6edf3BufferTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3writeTb4b4b4(Te6edf3jsonTb4b4b4.Te6edf3encodeToStringTb4b4b4(Te6edf3hardwareTb4b4b4)Tb4b4b4.Te6edf3encodeToByteArrayTb4b4b4(Tb4b4b4)Tb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tff7b72private Tff7b72class T56d364FakeDeviceLinkRepository Tb4b4b4: Te6edf3DeviceLinkRepository Tb4b4b4{

Tff7b72var Te6edf3reconcileCalls Tff7b72= T79c0ff0

Tff7b72var Te6edf3reconcileFailureTb4b4b4: Te6edf3Throwable? Tff7b72= Tff7b72null

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffensureImportedTb4b4b4(Tb4b4b4) Tff7b72= Tffa657Unit

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffreconcileTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3reconcileCalls Tff7b72+Tff7b72= T79c0ff1

Te6edf3reconcileFailureTff7b72?.Te6edf3let Tb4b4b4{ Tff7b72throw Tffa657it Tb4b4b4}

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetLinksForTargetTb4b4b4(Te6edf3platformioTargetTb4b4b4: Tffa657StringTb4b4b4, Te6edf3regionCodeTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Te6edf3ListTff7b72<Te6edf3DeviceLinkTff7b72> Tff7b72=

Te6edf3emptyListTb4b4b4(Tb4b4b4)

Tff7b72override Tff7b72fun Td2a8ffobserveAllLinksTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3DeviceLinkTff7b72>Tff7b72> Tff7b72= Te6edf3flowOfTb4b4b4(Te6edf3emptyListTb4b4b4(Tb4b4b4)Tb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72val Te6edf3json Tff7b72= Te6edf3Json Tb4b4b4{ Te6edf3ignoreUnknownKeys Tff7b72= Tff7b72true Tb4b4b4}

Tff7b72private Tff7b72val Te6edf3dispatchers Tff7b72=

Te6edf3CoroutineDispatchersTb4b4b4(Te6edf3DispatchersTb4b4b4.Te6edf3UnconfinedTb4b4b4, Te6edf3DispatchersTb4b4b4.Te6edf3UnconfinedTb4b4b4, Te6edf3DispatchersTb4b4b4.Te6edf3UnconfinedTb4b4b4)

Tff7b72private Tff7b72val Te6edf3knownHardware Tff7b72=

Te6edf3NetworkDeviceHardwareTb4b4b4(

Te6edf3hwModel Tff7b72= T79c0ff1Tb4b4b4,

Te6edf3hwModelSlug Tff7b72= Ta5d6ff"Ta5d6ffKNOWNTa5d6ff"Tb4b4b4,

Te6edf3platformioTarget Tff7b72= Ta5d6ff"Ta5d6ffknownTa5d6ff"Tb4b4b4,

Te6edf3architecture Tff7b72= Ta5d6ff"Ta5d6ffesp32Ta5d6ff"Tb4b4b4,

Te6edf3activelySupported Tff7b72= Tff7b72trueTb4b4b4,

Te6edf3displayName Tff7b72= Ta5d6ff"Ta5d6ffKnownTa5d6ff"Tb4b4b4,

Te6edf3images Tff7b72= Te6edf3listOfTb4b4b4(Ta5d6ff"Ta5d6ffknown.svgTa5d6ff"Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3remoteOnlyHardware Tff7b72=

Te6edf3NetworkDeviceHardwareTb4b4b4(

Te6edf3hwModel Tff7b72= T79c0ff2Tb4b4b4,

Te6edf3hwModelSlug Tff7b72= Ta5d6ff"Ta5d6ffREMOTE_ONLYTa5d6ff"Tb4b4b4,

Te6edf3platformioTarget Tff7b72= Ta5d6ff"Ta5d6ffremote-onlyTa5d6ff"Tb4b4b4,

Te6edf3architecture Tff7b72= Ta5d6ff"Ta5d6ffesp32Ta5d6ff"Tb4b4b4,

Te6edf3activelySupported Tff7b72= Tff7b72trueTb4b4b4,

Te6edf3displayName Tff7b72= Ta5d6ff"Ta5d6ffRemote OnlyTa5d6ff"Tb4b4b4,

Te6edf3images Tff7b72= Te6edf3listOfTb4b4b4(Ta5d6ff"Ta5d6ffremote-only.svgTa5d6ff"Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tff7b72private Tff7b72lateinit Tff7b72var Te6edf3databaseProviderTb4b4b4: Te6edf3FakeDatabaseProvider

Tff7b72private Tff7b72lateinit Tff7b72var Te6edf3apiTb4b4b4: Te6edf3FakeApiService

Tff7b72private Tff7b72lateinit Tff7b72var Te6edf3linksTb4b4b4: Te6edf3FakeDeviceLinkRepository

Tff7b72private Tff7b72lateinit Tff7b72var Te6edf3repositoryTb4b4b4: Te6edf3DeviceHardwareRepositoryImpl

Tf0883e@BeforeTest

Tff7b72fun Td2a8ffsetupTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3databaseProvider Tff7b72= Te6edf3FakeDatabaseProviderTb4b4b4(Tb4b4b4)

Te6edf3api Tff7b72= Te6edf3FakeApiServiceTb4b4b4(Te6edf3listOfTb4b4b4(Te6edf3knownHardwareTb4b4b4)Tb4b4b4)

Te6edf3links Tff7b72= Te6edf3FakeDeviceLinkRepositoryTb4b4b4(Tb4b4b4)

Te6edf3repository Tff7b72=

Te6edf3DeviceHardwareRepositoryImplTb4b4b4(

Te6edf3remoteDataSource Tff7b72= Te6edf3DeviceHardwareRemoteDataSourceTb4b4b4(Te6edf3apiTb4b4b4, Te6edf3dispatchersTb4b4b4)Tb4b4b4,

Te6edf3localDataSource Tff7b72= Te6edf3DeviceHardwareLocalDataSourceTb4b4b4(Te6edf3databaseProviderTb4b4b4)Tb4b4b4,

Te6edf3assetReader Tff7b72= Te6edf3FakeBundledAssetReaderTb4b4b4(Te6edf3listOfTb4b4b4(Te6edf3knownHardwareTb4b4b4)Tb4b4b4, Te6edf3jsonTb4b4b4)Tb4b4b4,

Te6edf3json Tff7b72= Te6edf3jsonTb4b4b4,

Te6edf3deviceLinkRepository Tff7b72= Te6edf3linksTb4b4b4,

Te6edf3dispatchers Tff7b72= Te6edf3dispatchersTb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tf0883e@AfterTest Tff7b72fun Td2a8fftearDownTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3databaseProviderTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)

Tf0883e@Test

Tff7b72fun Td2a8ffrepeatedMissingModelUsesOneSuccessfulCatalogRefreshTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runBlocking Tb4b4b4{

T8b949e// Sequential lookups can hit cache after the first fetch and never share a flight; prove single-flight

T8b949e// sharing by suspending the fake API response and overlapping the two lookups.

Te6edf3apiTb4b4b4.Te6edf3responseGate Tff7b72= Te6edf3CompletableDeferredTb4b4b4(Tb4b4b4)

Te6edf3coroutineScope Tb4b4b4{

Tff7b72val Te6edf3first Tff7b72= Te6edf3async Tb4b4b4{ Te6edf3repositoryTb4b4b4.Te6edf3getDeviceHardwareByModelTb4b4b4(Te6edf3hwModel Tff7b72= T79c0ff3T79c0ff7Tb4b4b4) Tb4b4b4}

Tff7b72val Te6edf3second Tff7b72= Te6edf3async Tb4b4b4{ Te6edf3repositoryTb4b4b4.Te6edf3getDeviceHardwareByModelTb4b4b4(Te6edf3hwModel Tff7b72= T79c0ff3T79c0ff7Tb4b4b4) Tb4b4b4}

Te6edf3apiTb4b4b4.Te6edf3responseGateTff7b72!!Tb4b4b4.Te6edf3completeTb4b4b4(Tffa657UnitTb4b4b4)

Te6edf3awaitAllTb4b4b4(Te6edf3firstTb4b4b4, Te6edf3secondTb4b4b4)

Tb4b4b4}

Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3apiTb4b4b4.Te6edf3hardwareCallsTb4b4b4, Ta5d6ff"Ta5d6ffconcurrent callers must share one fetchTa5d6ff"Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3linksTb4b4b4.Te6edf3reconcileCallsTb4b4b4, Ta5d6ff"Ta5d6ffconcurrent callers must share one reconcileTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ffreconciliationFailureDoesNotTriggerAnotherCatalogRefreshTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runBlocking Tb4b4b4{

T8b949e// The refresher records catalog success BEFORE calling reconcile(), so a reconcile failure must not

T8b949e// poison the success TTL window. A subsequent missing-model lookup must NOT cause another hardware

T8b949e// fetch, because the catalog was already recorded as fresh.

Te6edf3linksTb4b4b4.Te6edf3reconcileFailure Tff7b72= Te6edf3RuntimeExceptionTb4b4b4(Ta5d6ff"Ta5d6ffreconcile boomTa5d6ff"Tb4b4b4)

Te6edf3assertNullTb4b4b4(Te6edf3repositoryTb4b4b4.Te6edf3getDeviceHardwareByModelTb4b4b4(Te6edf3hwModel Tff7b72= T79c0ff3T79c0ff7Tb4b4b4)Tb4b4b4.Te6edf3getOrThrowTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3linksTb4b4b4.Te6edf3reconcileFailure Tff7b72= Tff7b72null

Te6edf3assertNullTb4b4b4(Te6edf3repositoryTb4b4b4.Te6edf3getDeviceHardwareByModelTb4b4b4(Te6edf3hwModel Tff7b72= T79c0ff3T79c0ff7Tb4b4b4)Tb4b4b4.Te6edf3getOrThrowTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3apiTb4b4b4.Te6edf3hardwareCallsTb4b4b4, Ta5d6ff"Ta5d6ffcatalog success must gate further hardware fetchesTa5d6ff"Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3linksTb4b4b4.Te6edf3reconcileCallsTb4b4b4, Ta5d6ff"Ta5d6ffretry outside TTL must not retry reconcile eitherTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ffforceRefreshBypassesRecentSuccessfulCatalogRefreshTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runBlocking Tb4b4b4{

Te6edf3repositoryTb4b4b4.Te6edf3getDeviceHardwareByModelTb4b4b4(Te6edf3hwModel Tff7b72= T79c0ff3T79c0ff7Tb4b4b4)Tb4b4b4.Te6edf3getOrThrowTb4b4b4(Tb4b4b4)

Te6edf3repositoryTb4b4b4.Te6edf3getDeviceHardwareByModelTb4b4b4(Te6edf3hwModel Tff7b72= T79c0ff3T79c0ff7Tb4b4b4, Te6edf3forceRefresh Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4.Te6edf3getOrThrowTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff2Tb4b4b4, Te6edf3apiTb4b4b4.Te6edf3hardwareCallsTb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff2Tb4b4b4, Te6edf3linksTb4b4b4.Te6edf3reconcileCallsTb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ffemptyForcedRefreshPreservesPreviouslyCachedRemoteCatalogTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runBlocking Tb4b4b4{

Te6edf3apiTb4b4b4.Te6edf3response Tff7b72= Te6edf3listOfTb4b4b4(Te6edf3remoteOnlyHardwareTb4b4b4)

Tff7b72val Te6edf3initial Tff7b72= Te6edf3repositoryTb4b4b4.Te6edf3getDeviceHardwareByModelTb4b4b4(Te6edf3hwModel Tff7b72= Te6edf3remoteOnlyHardwareTb4b4b4.Te6edf3hwModelTb4b4b4)Tb4b4b4.Te6edf3getOrThrowTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Te6edf3remoteOnlyHardwareTb4b4b4.Te6edf3displayNameTb4b4b4, Te6edf3initialTff7b72?.Te6edf3displayNameTb4b4b4)

Te6edf3assertNullTb4b4b4(Te6edf3repositoryTb4b4b4.Te6edf3getDeviceHardwareByModelTb4b4b4(Te6edf3hwModel Tff7b72= Te6edf3knownHardwareTb4b4b4.Te6edf3hwModelTb4b4b4)Tb4b4b4.Te6edf3getOrThrowTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3apiTb4b4b4.Te6edf3response Tff7b72= Te6edf3emptyListTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3afterEmptyRefresh Tff7b72=

Te6edf3repositoryTb4b4b4.Te6edf3getDeviceHardwareByModelTb4b4b4(Te6edf3hwModel Tff7b72= Te6edf3remoteOnlyHardwareTb4b4b4.Te6edf3hwModelTb4b4b4, Te6edf3forceRefresh Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4.Te6edf3getOrThrowTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Te6edf3remoteOnlyHardwareTb4b4b4.Te6edf3displayNameTb4b4b4, Te6edf3afterEmptyRefreshTff7b72?.Te6edf3displayNameTb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff2Tb4b4b4, Te6edf3apiTb4b4b4.Te6edf3hardwareCallsTb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff2Tb4b4b4, Te6edf3linksTb4b4b4.Te6edf3reconcileCallsTb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tff7b72class T56d364DeviceHardwareRefreshGateTest Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3gate Tff7b72= Te6edf3DeviceHardwareRefreshGateTb4b4b4(Te6edf3retryIntervalMs Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4, Te6edf3successTtlMs Tff7b72= T79c0ff1Te6edf3_000Tb4b4b4)

Tf0883e@Test

Tff7b72fun Td2a8fffreshCacheNeedsNoRefreshTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3assertFalseTb4b4b4(Te6edf3gateTb4b4b4.Te6edf3shouldRefreshTb4b4b4(Te6edf3nowMs Tff7b72= T79c0ff0Tb4b4b4, Te6edf3forceRefresh Tff7b72= Tff7b72falseTb4b4b4, Te6edf3cacheNeedsRefresh Tff7b72= Tff7b72falseTb4b4b4)Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8fffailedAttemptIsThrottledUntilRetryIntervalTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3assertTrueTb4b4b4(Te6edf3gateTb4b4b4.Te6edf3shouldRefreshTb4b4b4(Te6edf3nowMs Tff7b72= T79c0ff0Tb4b4b4, Te6edf3forceRefresh Tff7b72= Tff7b72falseTb4b4b4, Te6edf3cacheNeedsRefresh Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4)

Te6edf3gateTb4b4b4.Te6edf3recordAttemptTb4b4b4(T79c0ff0Tb4b4b4)

Te6edf3assertFalseTb4b4b4(Te6edf3gateTb4b4b4.Te6edf3shouldRefreshTb4b4b4(Te6edf3nowMs Tff7b72= T79c0ff9T79c0ff9Tb4b4b4, Te6edf3forceRefresh Tff7b72= Tff7b72falseTb4b4b4, Te6edf3cacheNeedsRefresh Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3gateTb4b4b4.Te6edf3shouldRefreshTb4b4b4(Te6edf3nowMs Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4, Te6edf3forceRefresh Tff7b72= Tff7b72falseTb4b4b4, Te6edf3cacheNeedsRefresh Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ffsuccessfulCatalogIsAuthoritativeForTtlTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3gateTb4b4b4.Te6edf3recordAttemptTb4b4b4(T79c0ff0Tb4b4b4)

Te6edf3gateTb4b4b4.Te6edf3recordSuccessTb4b4b4(T79c0ff1T79c0ff0Tb4b4b4)

Te6edf3assertFalseTb4b4b4(Te6edf3gateTb4b4b4.Te6edf3shouldRefreshTb4b4b4(Te6edf3nowMs Tff7b72= T79c0ff1Te6edf3_009Tb4b4b4, Te6edf3forceRefresh Tff7b72= Tff7b72falseTb4b4b4, Te6edf3cacheNeedsRefresh Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3gateTb4b4b4.Te6edf3shouldRefreshTb4b4b4(Te6edf3nowMs Tff7b72= T79c0ff1Te6edf3_010Tb4b4b4, Te6edf3forceRefresh Tff7b72= Tff7b72falseTb4b4b4, Te6edf3cacheNeedsRefresh Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ffforceRefreshAlwaysBypassesGateTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3gateTb4b4b4.Te6edf3recordAttemptTb4b4b4(T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)

Te6edf3gateTb4b4b4.Te6edf3recordSuccessTb4b4b4(T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3gateTb4b4b4.Te6edf3shouldRefreshTb4b4b4(Te6edf3nowMs Tff7b72= T79c0ff1T79c0ff0T79c0ff1Tb4b4b4, Te6edf3forceRefresh Tff7b72= Tff7b72trueTb4b4b4, Te6edf3cacheNeedsRefresh Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4)

Tb4b4b4}

Tb4b4b4}